package com.zzr.demo.redis.II.service;

import java.util.Set;

/**
 * @author: xiaomi
 * @date: 2021/10/11
 * @description: 使用 stream 实现消息队列
 */
public interface MessageQueueService {

    String addMessage(String key, String value);

    String getMessage(String recordId);

    long size();

    /**
     * 创建消费者组
     *
     * @param groupName
     */
    void createGroup(String groupName);

    /**
     * 删除消费者
     *
     * @param groupName
     * @return true:suc;false:fail
     */
    boolean destroyGroup(String groupName);

    Set<String> readGroup(String groupName, String consumerName);

    /**
     * 确认消息
     *
     * @param groupName
     * @param recordId
     * @return
     */
    boolean ack(String groupName, String recordId);
}

